88407d1e949de4bd404dedb62c67377767b5f6b4,bridge/src/main/java/io/rhiot/kafka/bridge/SourceBridgeEndpoint.java,SourceBridgeEndpoint,close,#,88

Before Change


		if (this.ebConsumer != null)
			this.ebConsumer.unregister();
		
		this.vertx.sharedData().getLocalMap(this.ebName).clear();
	}

	@Override

After Change


		if (this.producerSettledMode != null)
			this.producerSettledMode.close();
		
		if (this.producerUnsettledMode != null)
			this.producerUnsettledMode.close();
		
		if (this.ebConsumer != null)
			this.ebConsumer.unregister();
		
		if (this.ebName != null)
			this.vertx.sharedData().getLocalMap(this.ebName).clear();
	}

	@Override